package org.niit.app

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.AdClickData
import org.niit.common.TApp
import org.niit.controller.MengTimeController
import org.niit.handler.DataHandler

// ps：该案例执行步骤：删除对应Kafka主题和建立数据库的表 --> 运行app代码 --> 运行mock代码（模拟数据）

// 直接去获取数据的代码 以及 调用 Controller代码
object WeiTimeApp extends App with TApp{

  start(appName = "WeiTimeApp"){  // 继承TApp

    val weiTimeController = new WeiTimeController()

    val value: DStream[AdClickData] = DataHandler.KafkaDataHandler("BD1", "newBD1")  // 获取Kafka的数据，实时的数据分析（只需要修改后面的参数即主题）

    weiTimeController.dispatch(value)

    DataHandler.startAndAwait()

  }

}